package com.changfen.client.reactor;

import org.reactivestreams.Subscriber;
import org.reactivestreams.Subscription;
import reactor.core.publisher.Flux;

/**
 * @author 86180
 * @Classname ReactorTest
 * @Description TODO
 * @Date 2022/9/5 23:23
 */
public class ReactorTest {
    public static void main(String[] args) {
        Flux.just("feng","hua","xue","yue").subscribe(new Subscriber<String>() {
            @Override
            public void onSubscribe(Subscription subscription) {

            }

            @Override
            public void onNext(String s) {

            }

            @Override
            public void onError(Throwable throwable) {

            }

            @Override
            public void onComplete() {

            }
        });
    }
}
